package com.dexin.rabbitmq.service;

import com.alibaba.fastjson.JSONObject;
import com.dexin.rabbitmq.model.User;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component("sendService")
public class SendService {
    @Autowired
    private AmqpTemplate template;
    public void send(){
        User user=new User();
        user.setId(2L);
        user.setName("zs");

        //转换并发送消息
        //参数1 我们自定义的交换机名称  就是Exchange名
        //参数2 我们自定义的路由key的名 就是RoutingKey 名字
        //参数3 就是我们需要发送具体的消息数据

        template.convertAndSend("myExchange","myRoutingKey", JSONObject.toJSONString(user));
    }
}
